View Javadoc
   package com.fc.taglibs.castor.integration.tomcat;
   
   import java.io.PrintWriter;
   import java.io.StringWriter;
   import java.io.Serializable;
   import java.lang.reflect.Method;
   import java.util.Enumeration;
   import java.util.Hashtable;
   import javax.naming.Context;
  import javax.naming.InitialContext;
  import javax.naming.Name;
  import javax.naming.NamingException;
  import javax.naming.RefAddr;
  import javax.naming.Reference;
  import javax.naming.spi.ObjectFactory;
  
  import javax.transaction.TransactionManager;
  
  import org.xml.sax.InputSource;
  
  import org.exolab.castor.jdo.JDO;
  import org.exolab.castor.jdo.Database;
  import org.exolab.castor.jdo.conf.Database;
  import org.exolab.castor.mapping.MappingException;
  import org.exolab.castor.xml.Unmarshaller;
  import org.exolab.castor.persist.spi.LogInterceptor;
  
  
  public class CastorJdoObjectFactory implements ObjectFactory,LogInterceptor
  {
  	/*
  	* Declare loggers (if needed)
  	*/ 
  	private PrintWriter writer;
  	
  	/*
  	* The JDO properties set from the
  	* attributes in our server.xml
  	*/ 
  	private String _config = null;
  	private String _description = null;
  	private int _lockTimeout = 0;
  	private boolean _loggingEnabled = false;
  	private boolean _commonClasspath = false;
  	private boolean _autoStore = false;
  	private boolean _databasePooling = false;
  	private String _transactionManager = null;
  	
  	public Object getObjectInstance(Object obj,
  	    Name name, Context nameCtx, Hashtable environment)
  	    throws NamingException 
  	{
  	/*
  	* Declare the JDO and related Castor bits we need.
  	*/
  	JDO jdo = null;
  	org.exolab.castor.jdo.conf.Database database = null;
  	Unmarshaller unmarshaller = null;
  
  	
  	
  	
  	/*
  	* Retrieve the JDO properties from our attributes
  	*/
  	Reference ref = (Reference) obj;
  	Enumeration addrs = ref.getAll();
  	while (addrs.hasMoreElements()) {
  	    RefAddr addr = (RefAddr) addrs.nextElement();
  	    String attName = addr.getType();
  	    String attValue = (String) addr.getContent();
  	    if (attName.equals("Configuration")) 
  		{
  	        _config = attValue;
  	    }
  		else if (attName.equals("Description")) 
  		{
  	        _description = attValue;
  	    }
  		else if (attName.equals("LockTimeout")) 
  		{
  	        try {
  	        	_lockTimeout = Integer.parseInt(attValue);
  	        } catch (NumberFormatException e) {
  	            throw new NamingException("CastorJdoObjectFactory: Invalid 'LockTimeout' value " + attValue);
  	        }
  	    }
  		else if (attName.equals("LoggingEnabled")) 
  		{
  			_loggingEnabled = new Boolean(attValue).booleanValue();
  		}
  		else if (attName.equals("CommonClasspath")) 
  		{
  			_commonClasspath = new Boolean(attValue).booleanValue();
  	    }
  		else if (attName.equals("AutoStore")) 
  		{
  			_autoStore = new Boolean(attValue).booleanValue();
  	    }
 		else if (attName.equals("DatabasePooling")) 
 		{
 			_databasePooling = new Boolean(attValue).booleanValue();
 	    }
 		else if (attName.equals("TransactionManager")) 
 		{
 			_transactionManager = attValue;
 	    }
 		
 	}
 
 	
 	try 
 	{	
 		/*
 		* Create the JDO instance
 		*/
 		System.out.println("Castor JDO: Creating new JDO instance." );
 		System.out.println("Configuration file : " + _config );
 		System.out.println("Description : " +_description );
 		System.out.println("Lock timeout: " +_lockTimeout );
 		System.out.println("Logging enabled : " +_loggingEnabled );
 		System.out.println("Common classpath : " +_commonClasspath );
 		System.out.println("Autostore : " +_autoStore );
 		System.out.println("Database pooling : " +_databasePooling );
 		System.out.println("Transaction manager : " +_transactionManager );
 			
 		jdo = new JDO();
 		jdo.setClassLoader( getClass().getClassLoader() );
 		/*
 		* We assume that the database is in WEB-INF/classes/
 		* and load it as a resource. The name of the database.xml
 		* is got from the server.xml attribute.
 		*/
 		jdo.setConfiguration(getClass().getResource("/" + _config).toString());
 		unmarshaller = new Unmarshaller(org.exolab.castor.jdo.conf.Database.class);
 		database = (org.exolab.castor.jdo.conf.Database) unmarshaller.unmarshal(new InputSource(getClass().getResource("/" + _config).toString()));
 		jdo.setDatabaseName(database.getName());
 		
 		/*
 		* Set the other JDO properties from our attributes
 		*/
 		jdo.setDescription(_description);
 		
 		if (!_commonClasspath)
 			jdo.setClassLoader(null);
 			
 	
 		if (_loggingEnabled)
 		{
 			jdo.setLogInterceptor( this );
 		}
 		else
 		{
 			jdo.setLogInterceptor( null );
 		}
 		
 		jdo.setLockTimeout(_lockTimeout);
 		/*
 		* Older Castor versions older don't have these methods,
 		* we'll use reflection for backward compatibility
 		* jdo.setAutoStore(_autoStore);
 		* jdo.setDatabasePooling(_dbpooling);
 		* Thanks Oleg Nitz!
 		*/
 		
 		Method m;
 		try 
 		{
 			// 0.9.4
 			m = jdo.getClass().getMethod(	"setAutoStore",
 											new Class[] {boolean.class});
 			m.invoke(jdo, new Object[] {new Boolean(_autoStore)});
 		} 
 		catch (Exception ex) 
 		{
 			
 		}
 		
 		try 
 		{
 			// 0.9.3
 			m = jdo.getClass().getMethod(	"setDatabasePooling",
 											new Class[] {boolean.class});
 			m.invoke(jdo, new Object[] {new Boolean(_databasePooling)});
 		} 
 		catch (Exception ex) 
 		{
 			
 		}
 
 			
 		if (_transactionManager!=null)
 		{
 			jdo.setTransactionManager( _transactionManager );
 		}
 		
 		
 	}
 	catch (Exception e)
 	{
 		System.out.println("Castor JDO: Exception thrown in CastorJdoObjectFactory: " + e.getMessage());
 		throw new NamingException(e.getMessage());
 	}	
 		// Return the customized instance
 		return (jdo);
 	
 	}
 	
 	// LogInterceptor implementation for Castor 0.8 ----------------------
 	public void loading(Class objClass, Object identity) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: Storing " + objClass.getName() + " (" + identity + ")" );
 		}
 	}
 	
 	
 	public void creating(Class objClass, Object identity) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: Storing " + objClass.getName() + " (" + identity + ")" );
 		}
 	}
 	
 	
 	public void removing(Class objClass, Object identity) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: Storing " + objClass.getName() + " (" + identity + ")" );
 		}
 	}	
 	
 	
 	public void storing(Class objClass, Object identity) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: Storing " + objClass.getName() + " (" + identity + ")" );
 		}
 	}
 	
 	
 	// LogInterceptor implementation for Castor 0.9 ----------------------
 	public void loading(Object objClass, Object identity) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: Storing " + objClass + " (" + identity + ")" );
 		}
 	}
 	
 	
 	public void creating(Object objClass, Object identity) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: Storing " + objClass + " (" + identity + ")" );
 		}
 	}
 	
 	
 	public void removing(Object objClass, Object identity) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: Storing " + objClass + " (" + identity + ")" );
 		}
 	}
 	
 	
 	public void storing(Object objClass, Object identity) 
 	{
 		if (_loggingEnabled) 
 		{
 			System.out.println("Castor JDO: Storing " + objClass + " (" + identity + ")" );
 		}
 	}
 	
 	
 	// LogInterceptor implementation
 	
 	public void storeStatement(String statement) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: " + statement);
 		}
 	}
 	
 	
 	public void queryStatement(String statement) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: " + statement);
 		}
 	}
 	
 	
 	public void message(String message) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: " + message);
 		}
 	}
 	
 	
 	public void exception(Exception except) 
 	{
 		if (_loggingEnabled)
 		{
 			System.out.println("Castor JDO: " + except.getMessage());
 		}
 	}
 	
 	public PrintWriter getPrintWriter()
 	{
 		if (writer == null)
 		{
 			StringWriter sw = new StringWriter();
 			writer = new PrintWriter(sw);	
 		}
 	return writer;
 	}
 
 }